package com.fancy.middleware.common.handler.disruptor;

import com.fancy.middleware.common.beans.DomainWrapper;
import com.lmax.disruptor.EventHandler;
import lombok.extern.slf4j.Slf4j;

@Slf4j
public class DomainEventHandler implements EventHandler<DomainWrapper> {

    @Override
    public void onEvent(DomainWrapper frameDataWrapper, long sequence, boolean endOfBatch) throws Exception {
        log.info("{}", new String(frameDataWrapper.getDomain().getFrameData().getData()));
    }
}
